package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.ImportBinderConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * 导入 消息队列
 * @author 梁鲁江
 * @date 2019/2/22 18:48
 * @since v1.0
 * @version v1.0
 */
@Service("importConsumerBinder")
public interface ImportConsumerBinder {
    /**
     * 客户
     */
    @Input(ImportBinderConstant.IMPORT_ADD_INPUT)
    SubscribableChannel importAdd();

    @Input(ImportBinderConstant.IMPORT_LARGE_NUM_ADD_INPUT)
    SubscribableChannel importLargeNumAdd();
}
